package com.shujia

import scala.io.Source


object FlinkRunner extends FlinkTool {
  /**
    * 将sql 文件名以参数的方式传进来
    *
    */
  override def run(args: Array[String]): Unit = {
    val sqlFileName = args(0)

    //读取sql文件获取文件中的sql
    val sql: String = Source
      .fromFile(sqlFileName)
      .getLines()
      .toList
      .mkString("\n")


    bsTableEnv.executeSql(sql)


  }
}
